package com.lvmama.rhino.common.utils.serialization

import com.esotericsoftware.kryo.Kryo
import com.lvmama.rhino.common.entity.NginxMan
import com.lvmama.rhino.common.utils.kafka.KafkaPayloadStringCodec
import org.apache.spark.serializer.KryoRegistrator

/**
  * Created by yuanxiaofeng on 2016/6/27.
  */
class ManGodStreamingRegistrator extends KryoRegistrator{
  override def registerClasses(kryo: Kryo): Unit = {
    kryo.register(classOf[NginxMan])
    kryo.register(classOf[KafkaPayloadStringCodec])
  }
}
